package org.nanotek.mq;

import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.listener.DefaultMessageListenerContainer;

public class QueueSenderTest {

	public QueueSenderTest() {
	}

	private static ClassPathXmlApplicationContext ctx;
	

	/**
	 * @param args
	 * @throws InterruptedException 
	 */
	public static void main(String[] args) throws InterruptedException {
		ctx = new ClassPathXmlApplicationContext(new String[] {"activemq-config/base-activemq-context.xml"});
		QueueSender sender = (QueueSender) ctx.getBean("queueSender");
		for (int i = 0 ; i < 1000 ; i++){ 
			sender.send("This is a test message " + i);
		}
	}

}
